package com.sudo.service.impl;

import com.sudo.common.enums.UserParams;
import com.sudo.common.utils.JsonUtils;
import com.sudo.common.utils.RedisOperator;
import com.sudo.common.utils.SysInfoUtil;
import com.sudo.common.utils.SysInfoUtils;
import com.sudo.mapper.my.SysCpuLogMapper;
import com.sudo.pojo.SysCpuLog;
import com.sudo.service.BaseService;
import com.sudo.service.SysCpuLogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

/**
 * @author：为道日损 2020-07-03 14:47
 * webSite：https://www.sudo.ren
 */
@Service
public class SysCpuLogServiceImpl extends BaseService implements SysCpuLogService {

    @Autowired
    private SysCpuLogMapper sysCpuLogMapper;

    @Autowired
    private RedisOperator redisOperator;

    @Override
    public void insertCpuLogToRedis() {
        SysCpuLog sysCpuLog = SysInfoUtils.dynamicCpu();
        redisOperator.lpush(UserParams.REDIS_SYS_INFO.value+":"+UserParams.CPU.value,
                JsonUtils.objectToJson(sysCpuLog));
    }

    @Override
    public void insertCpuLogFromRedisToMysql() {
        List<SysCpuLog> sysCpuLogList = new ArrayList<>();
        for (int i = 0; i < 60; i++) {
            String jsonData = redisOperator.rpop(UserParams.REDIS_SYS_INFO.value+":"+UserParams.CPU.value);
            SysCpuLog sysCpuLog = JsonUtils.jsonToPojo(jsonData, SysCpuLog.class);
            sysCpuLogList.add(sysCpuLog);
        }
        if (!CollectionUtils.isEmpty(sysCpuLogList)){
            sysCpuLogMapper.insertList(sysCpuLogList);
        }
    }

    @Override
    public List<SysCpuLog> getCpuLogListFromRedis(Integer num) {
        List<SysCpuLog> sysCpuLogList = new ArrayList<>();
        List<String> cpuLogArr = redisOperator.lrange(UserParams.REDIS_SYS_INFO.value + ":" + UserParams.CPU.value, 0, num);
        for (String s : cpuLogArr) {
            SysCpuLog sysCpuLog = JsonUtils.jsonToPojo(s, SysCpuLog.class);
            sysCpuLogList.add(sysCpuLog);
        }
        Collections.reverse(sysCpuLogList);
        return sysCpuLogList;
    }


}
